package c.e.b.h.e.k;

import c.e.a.b.g.g;
import c.e.a.b.g.h;
import java.util.concurrent.Callable;

/* compiled from: Utils */
public class c1 implements Runnable {
    public final /* synthetic */ Callable a;
    public final /* synthetic */ h b;

    /* compiled from: Utils */
    public class a implements c.e.a.b.g.a<T, Void> {
        public Object a(g gVar) throws Exception {
            h hVar;
            if (gVar.k()) {
                hVar = c1.this.b;
                hVar.a.n(gVar.h());
            } else {
                hVar = c1.this.b;
                hVar.a.m(gVar.g());
            }
            return null;
        }
    }

    public c1(Callable callable, h hVar) {
        this.a = callable;
        this.b = hVar;
    }

    public void run() {
        try {
            ((g) this.a.call()).d(new a());
        } catch (Exception e) {
            this.b.a.m(e);
        }
    }
}
